<?php


namespace App\Queue\SmsSend;


use EasySwoole\Component\Process\AbstractProcess;
use EasySwoole\Queue\Job;

class SmsSendProcess extends AbstractProcess
{

    protected function run($arg)
    {
        go(function (){
            SmsSendQueue::getInstance()->consumer()->listen(function (Job $job){
                var_dump($job->getJobData());
            });
        });
    }
}